package com.cn;

public class MsgWorker {
	private MsgExecutor send = null;
	private MsgExecutor recv = null;

	public void addSendTask(int which, AWork work) {
		send.addTask(which, work);
	}
	
	public void addRecvTask(int which, AWork work) {
		recv.addTask(which, work);
	}

	public void shutdown() {
		send.shutdown();
		recv.shutdown();
	}

	public void start() {
		send = new MsgExecutor("消息发送队列", 100, -1);
		recv = new MsgExecutor("消息接收队列", 100, -1);
	}
}
